import Recommender.RecommenderTagBased_Product as re
import datetime

from Core.Config import *
config = Config()
database = config.Mysql()
realtime = config.RealTime(db='stock-rec-flow')
#database.Upsert("rec_article", "user_tag", {"user_pin": "-Azrael-" , "tag_id": 205}, {"user_pin": "-Azrael-", "tag_id": 205 , "tag_weight": 1, "update_weight_time": datetime.datetime.now()})
#debug = 1
realtime.Clear()
re.Add_Tag_on_User_Batch(database, realtime , {})

a = realtime.GetHashDocument("User_Tags_Batch1","不倒翁lxk")
debug =1
